package com.acdc.mqtt.service;

/**
* 消息处理器接口
*/
@FunctionalInterface
public interface MessageHandler {
    /**
     * 处理消息
     * @param topic 主题
     * @param message 消息内容
     */
    void handleMessage(String topic, String message);
}
